package com.ming.rabbitmq.one;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class Producer {
//    队列名称
    public static String name = "hello";
//    发消息
public static void main(String[] args) throws Exception {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("192.168.137.66");
    factory.setVirtualHost("/");
    factory.setUsername("root");
    factory.setPassword("123456");
    Connection connection = factory.newConnection();
//    获取信道
    Channel channel = connection.createChannel();
//    获取队列
//                     队列名 是否持久化 是否和其他消费者共享 是否自动删除 其他参数
    channel.queueDeclare(name,false,false,false,null);
    String message = "hello world";
//    发布信息
//        交换机 （路由key值）队列名 其他参数 消息体
    channel.basicPublish("",name,null,message.getBytes());
    System.out.println("消息发送完毕");
}






}
